package org.example.test.two;

import com.rabbitmq.client.Channel;
import org.example.test.util.RabbitMQUtils;

import java.util.Scanner;

// 生产者
public class Task01 {
    public static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtils.getChannel();
        // 产生一个队列(参数1：队列名称，参数2：是否持久化(磁盘)，默认情况消息存储在内存中，参数3：是否只提供给一个消费者消费，是否进行消息共享，参数4：是否自动删除，参数5：其他参数)
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);
        // 从控制台当中接受信息
        Scanner scanner = new Scanner(System.in);
        while (scanner.hasNext())
        {
            String message = scanner.next();
            // 发送消息给队列(参数1：交换机名称，如果没有指定则使用默认Default Exchage，参数2：队列名称，参数3：消息的属性，参数4：消息内容)
            channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
            System.out.println("发送消息完成：" + message);
        }
    }
}
